
#ifndef RTMP_INCLUDE_SERVER_H_
#define RTMP_INCLUDE_SERVER_H_

#include <cstdint>
#include <map>
#include <memory>
#include "../../public_module/public_module_define.h"


class RtmpConnection;
class RtmpServer : public std::enable_shared_from_this<RtmpServer>
{
public:
    RtmpServer();
    void RunRtmpServer(int listen_port=1935);
private:
    Loop m_loop;
    std::shared_ptr<Server> m_server;    
private:
    std::map<int64_t, std::shared_ptr<RtmpConnection>> m_client_conn_map;
};

#endif
